日期函数 TO_TIMESTAMP 语法 TIMESTAMP TO_TIMESTAMP(BIGINT ...

0 简介 CREATE 语句用于向当前或指定的 Catalog 中注册表、视图或函数。注册后的表、视图和函数可以在 SQL 查询中使用。 目前 Flink SQL 支持下列 CREATE 语句： ...

来源：https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/table/sql/queries.html 0 简介 ...

INSERT 语句用来向表中添加行。 1 执行 INSERT 语句 单条 INSERT 语句，可以使用 TableEnvironment 中的 executeSql() 方法执行，也可以在 SQL ...

1.什么是 CEP 概念： 　　一个或多个由简单事件构成的事件流通过一定的规则匹配，然后输出用户想得到的数据，满足规则的复杂事件。 特征：  目标：从 ...

字符串函数 STR_TO_MAP 语法 MAP STR_TO_MAP(VARCHAR text) MAP STR_TO_MAP(VARCHAR text, V ...

0 简介 自定义函数（UDF）是一种扩展开发机制，可以用来在查询语句里调用难以用其他方式表达的频繁使用或自定义的逻辑。 自定义函数可以用 JVM 语言（例如 Java 或 Scala）或 Pyth ...

1 常规窗口　 　　时间语义，要配合窗口操作才能发挥作用。最主要的用途，当然就是开窗口、根据时间段做计算了。下面我们就来看看Table API和SQL中，怎么利用时间字段做窗口操作。 在Table ...

0 函数 Flink 允许用户在 Table API 和 SQL 中使用函数进行数据的转换。 1 函数类型 Flink 中的函数有两个划分标准。 一个划分标准是：系统（内置）函数和 Catal ...

1 基本程序结构 Table API 和 SQL 的程序结构，与流式处理的程序结构类似；也可以近似地认为有这么几步：首先创建执行环境，然后定义source、transform和sink。 具体操作 ...